f883209257ec162a66b61778c9d01d74fbe938dd,tests/junit/org/jgroups/tests/ConcurrentStartFlushTest.java,ConcurrentStartFlushTest,testFlushStartedByOneButCompletedByOther,#,107

Before Change



        Util.sleep(1000);
        System.out.println("Stopping flush at C2");
        c2.stopFlush();

        Util.sleep(1000);
        System.out.println("Stopping flush at C1");

After Change


    public void testFlushStartedByOneButCompletedByOther() throws Exception {
        c1 = createChannel();
        r1=new Receiver("C1", c1);
        c2 = createChannel();
        r2=new Receiver("C2", c2);
        c3 = createChannel();
        r3=new Receiver("C3", c3);
        c1.setReceiver(r1);
        c2.setReceiver(r2);
        c3.setReceiver(r3);
        
        c1.connect("test");
        c2.connect("test");
        c3.connect("test");

        Util.sleep(1000);

        System.out.println("starting flush at C1");
        boolean rc=c1.startFlush(TIMEOUT, false);
        assertTrue(rc);
        Util.sleep(500);
        
        Util.sleep(1000);
        System.out.println("Stopping flush at C2");
        c2.stopFlush();
        
        System.out.println("starting flush at C2");
        rc=c2.startFlush(TIMEOUT, false);